set hive.exec.dynamic.partition=true;
set hive.exec.dynamic.partition.mode='nonstrict';
set hive.exec.max.dynamic.partitions=400;
set hive.exec.max.dynamic.partitions.pernode=400;


insert overwrite table jms_dm.dm_arbit_abnormal_duty_detail_dt
select
     arbit.id
    ,arbit.waybill_no
    ,base.order_source_code          --订单来源编码
    ,base.order_source_name          --订单来源名称
    ,base.ziyou_duty_type            --自有平台责任类型
    ,base.ziyou_duty_main_code       --自有平台责任主体编码
    ,base.ziyou_duty_main_name       --自有平台责任主体名称
    ,base.ziyou_duty_main_type       --自有平台责任主体类型
    ,base.ziyou_duty_main_fran_code  --自有平台责任加盟商编码
    ,base.ziyou_duty_main_fran_name  --自有平台责任加盟商名称
    ,base.ziyou_duty_main_agent_code --自有平台责任代理区编码
    ,base.ziyou_duty_main_agent_name --自有平台责任代理区名称
    ,base.ziyou_duty_provider_code   --自有平台责任省份编码
    ,base.ziyou_duty_provider_desc   --自有平台责任省份名称
    ,base.ziyou_duty_shipment_no     --自有平台责任任务号
    ,base.ziyou_duty_shipment_name   --自有平台责任任务号名称
    ,base.zy_dynamic_scan_time       --自有平台实际扫描时间
    ,base.zy_static_scan_time        --自有平台静态扫描时间
    ,arbit.dt
from (
    select
        id
       ,waybill_no
       ,dt
    from jms_dwd.dwd_arbitration_dt
    where dt = '{{ execution_date | cst_ds }}'
) arbit
left join (
    select
         waybill_no
        ,order_source_code          --订单来源编码
        ,order_source_name          --订单来源名称
        ,ziyou_duty_type            --自有平台责任类型
        ,ziyou_duty_main_code       --自有平台责任主体编码
        ,ziyou_duty_main_name       --自有平台责任主体名称
        ,ziyou_duty_main_type       --自有平台责任主体类型
        ,ziyou_duty_main_fran_code  --自有平台责任加盟商编码
        ,ziyou_duty_main_fran_name  --自有平台责任加盟商名称
        ,ziyou_duty_main_agent_code --自有平台责任代理区编码
        ,ziyou_duty_main_agent_name --自有平台责任代理区名称
        ,ziyou_duty_provider_code   --自有平台责任省份编码
        ,ziyou_duty_provider_desc   --自有平台责任省份名称
        ,ziyou_duty_shipment_no     --自有平台责任任务号
        ,ziyou_duty_shipment_name   --自有平台责任任务号名称
        ,zy_dynamic_scan_time       --自有平台实际扫描时间
        ,zy_static_scan_time        --自有平台静态扫描时间
    from jms_dm.dm_whole_decide_duty_base_dt
    where dt between date_sub('{{ execution_date | cst_ds }}',20) and '{{ execution_date | cst_ds }}'
) base on arbit.waybill_no = base.waybill_no
where base.waybill_no is not null
